package com.github.zhijieqing.socket.cluster.common.listener;

import java.util.EventListener;

public interface MessageListener<M> extends EventListener {
    /**
     * Invokes on every message in topic
     *
     * @param channel of topic
     * @param msg topic message
     */
    void onMessage(M msg);
}
